Search results
198 packages found
Convert a string/promise/array/iterable/asynciterable/buffer/typedarray/arraybuffer/object into a stream
Pipe a stream into a string, collect value with callback or promise
iopa-common-stream is a core utility library to create iopa.Body streams
Convert a node.js stream into an iterator.
Convert streams (readable or writable) to promises
A library to create automated metrics over various async pattern
Core function (map, filter, flatten, buffer, promise-map) to use with streams
listen stream to be ready and return a promise what is resolved with success and rejected with error event
A collection of utilities for async iterables. Designed to replace your streams.
- async
- generators
- async generators
- async iterables
- iterators
- async iterators
- promise
- stream
- fp
- transform
- generator functions
- async generator functions
- bluestream
- ramda
Write to streams with a promise-returning function
* Convert an absolute path to a tilde path: `/Users/YourUserName/dev` → `~/dev` * Inspired by [tilify](https://github.com/sindresorhus/tildify) by [Sindre Sorhus](https://github.com/sindresorhus) * Since tildify uses ES6 syntax, I created this package to
- includes
- sham
- endpoint
- ArrayBuffer#slice
- mkdirp
- zero
- side
- io-ts
- linux
- regular expressions
- route53
- HyBi
- queue
- watch
- View more
Small wrapper for streams that allows them to be treated as promises
Async method to concatenate a stream into a buffer
append any kind of values to a DOM attribute
Create an async function from anything (promise, stream, object)
A lean, zero dependency library to provide a useful base for your project. Checksums, cryptography, codecs, date-times, error-checking-codes, logging, pseudorandom number generation. The tools you need for any project. Secure build pipeline, provenance
- call
- watchFile
- awesomesauce
- encryption
- exit-code
- utility
- bdd
- typeerror
- parse
- intrinsic
- ratelimit
- 6to5
- parent
- reducer
- View more
Create streams from promises
Designed to be used with MobX-State-Tree to create asynchronous actions using RxJS.
- Rx
- RxJS
- ReactiveX
- ReactiveExtensions
- Streams
- Observables
- Observable
- Stream
- mobx
- mobx-state-tree
- promise
- reactive
- frp
- functional-reactive-programming
A through stream that does CPU throttling to avoid full CPU usage
Throttle streams of data while passing them through promises an timers. Use various valves to discard redundant data points.